github.com/gotd/td/internal/mtproto.Conn.rpc (field)

12 uses

	github.com/gotd/td/internal/mtproto (current package)
		conn.go#L57: 	rpc           *rpc.Engine
		conn.go#L149: 		rpc:               opt.engine,
		conn.go#L156: 	if conn.rpc == nil {
		conn.go#L157: 		conn.rpc = rpc.New(conn.writeContentMessage, rpc.Options{
		conn.go#L175: 	c.rpc.ForceClose()
		handle_ack.go#L18: 	c.rpc.NotifyAcks(ack.MsgIDs)
		handle_bad_msg.go#L55: 		c.rpc.NotifyError(bad.BadMsgID, &badMessageError{Code: bad.ErrorCode})
		handle_bad_msg.go#L63: 		c.rpc.NotifyError(bad.BadMsgID, &badMessageError{Code: bad.ErrorCode, NewSalt: bad.NewServerSalt})
		handle_result.go#L57: 		c.rpc.NotifyError(res.RequestMessageID, tgerr.New(rpcErr.ErrorCode, rpcErr.ErrorMessage))
		handle_result.go#L65: 	return c.rpc.NotifyResult(res.RequestMessageID, b)
		rpc.go#L32: 	if err := c.rpc.Do(ctx, req); err != nil {
		rpc.go#L42: 			return c.rpc.Do(ctx, req)